package com.example.commom.global;

/**
 *  Kafka  常量
 */
public class KafkaConstants {

    /**
     *  kafka groupId
     */
    public static final String KAFKA_GROUP_ID = "firstTopic001";

    /**
     *  kafka 审核书籍的 topic
     */
    public static final String KAFKA_CHECK_BOOK_TOPIC = "KAFKA_CHECK_BOOK_TOPIC";

    /**
     *  kafka 审核章节的 topic
     */
    public static final String KAFKA_CHECK_CHAPTER_TOPIC = "KAFKA_CHECK_CHAPTER_TOPIC";


    /**
     *  kafak 用户登录状态的 topic
     */
    public static final String KAFKA_LOGIN_STATUS_TOPIC = "login-status-topic";

    /**
     *  kafak 管理员 登录状态的 topic
     */
    public static final String KAFKA_ADMIN_LOGIN_STATUS_TOPIC = "admin-login-status-topic";

    /**
     *  kafka 修改用户名时, 同步更改书籍作者
     */
    public static final String KAFKA_UPDATE_BOOK_INFO = "update-book-info";

    /**
     *  kafka 修改用户信息的 topic
     */
    public static final String KAFKA_UPDATE_USER_INFO = "update-user-info";

    /**
     *  kafka 删除评论的 topic
     */
    public static final String KAFKA_USER_FOLLOW_TOPIC = "KAFKA_USER_FOLLOW_TOPIC";

    /**
     *  kafka 同步更新/插入 书籍的 topic
     */
    public static final String KAFKA_BOOK_UPDATE_INSERT_ES = "KAFKA_BOOK_UPDATE_INSERT_ES";

    /**
     *  kafka 同步删除书籍的 topic
     */
    public static final String KAFKA_BOOK_DELETE_ES = "KAFKA_BOOK_DELETE_ES";

    /**
     *  kafka 同步更新/插入章节的 topic
     */
    public static final String KAFKA_CHAPTER_INSERT_UPDATE_ES = "KAFKA_CHAPTER_INSERT_UPDATE_ES";

    /**
     *  kafka 同步删除章节的 topic
     */
    public static final String KAFKA_CHAPTER_DELETE_ES = "KAFKA_CHAPTER_DELETE_ES";
}
